package cn.bootx.demo.core.mq.mqtt;

import lombok.RequiredArgsConstructor;
import org.eclipse.paho.client.mqttv3.IMqttMessageListener;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.springframework.stereotype.Component;

/**   
* mqtt消息接收器
* @author xxm  
* @date 2022/5/30 
*/
@Component
@RequiredArgsConstructor
public class DemoMqttMessageListener implements IMqttMessageListener {


    @Override
    public void messageArrived(String topic, MqttMessage message) {

    }
}
